package com.corner.system.service.impl;

import ch.qos.logback.core.util.TimeUtil;
import com.corner.common.annotation.DataScope;
import com.corner.common.constant.UserConstants;
import com.corner.common.core.domain.TreeSelect;
import com.corner.common.core.domain.entity.SysDept;
import com.corner.common.core.domain.entity.SysRole;
import com.corner.common.core.domain.entity.SysUser;
import com.corner.common.core.text.Convert;
import com.corner.common.exception.GlobalException;
import com.corner.common.exception.ServiceException;
import com.corner.common.utils.DateUtils;
import com.corner.common.utils.SecurityUtils;
import com.corner.common.utils.StringUtils;
import com.corner.common.utils.spring.SpringUtils;
import com.corner.system.domain.*;
import com.corner.system.mapper.*;
import com.corner.system.service.ISysDeptService;
import com.corner.system.service.JxMqttService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.lang.reflect.Field;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 获取泵站数据 服务实现
 * 
 * @author chn
 */
@Slf4j
@Service
public class JxMqttServiceImpl implements JxMqttService
{

    @Autowired
    private SysPlcMapper plcMapper;
    @Autowired
    private SysDbMapper dbMapper;
    @Autowired
    private SysJzMapper jzMapper;
    @Autowired
    private SysSzMapper szMapper;
    @Autowired
    private SysJxCommonDataMapper commonDataMapper;

    @Override
    public MqttReq selectWswDataList(Long bid) throws NoSuchFieldException, IllegalAccessException {

        List wswData = new ArrayList();
        Map<Object, Object> bigMap = new HashMap();

        // 在线状态、时间、数据
        Map CommonData = commonDataMapper.selectHjAndMjData(bid);

        if(CommonData == null){
//            throw new GlobalException("泵站"+bid+"未查询到数据！");
            log.info("泵站"+bid+"未查询到数据！");
            return null;
        }

        if(StringUtils.isBlank((String)CommonData.get("online"))||!"在线".equals(CommonData.get("online"))){
//            throw new GlobalException("泵站"+bid+"不在线！");
            log.info("泵站"+bid+"不在线！");
            return null;
        }

        Date timeBegin = (Date)CommonData.get("timeBegin");
        String dateStr = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", timeBegin);

        // 环境监测
        Object yg = CommonData.get("yg");
        Map ygm = new HashMap<>();
        ygm.put("time",dateStr);
        ygm.put("value",yg);
        Object sj = CommonData.get("sj");
        Map sjm = new HashMap<>();
        sjm.put("time",dateStr);
        sjm.put("value",sj);
        Object rq = CommonData.get("rq");
        Map rqm = new HashMap<>();
        rqm.put("time",dateStr);
        rqm.put("value",rq);

        bigMap.put("yg",ygm);
        bigMap.put("sj",sjm);
        bigMap.put("rq",rqm);


        //门禁
        Object zt = CommonData.get("zt");
        Map ztm = new HashMap<>();
        ztm.put("time",dateStr);
        ztm.put("value",zt);
        bigMap.put("zt",ztm);


        //bigMap.put("timeBegin",dateStr);

        //plc总数
        int plcCounts = 12;

        for( int i = 1; i <= plcCounts; i++ ){
            Plc p = plcMapper.selectPlcData(bid, i);
            if(p == null){
                log.info("泵站"+bid+"未查询到PLC数据！");
                continue;
                //throw new GlobalException("泵站"+bid+"未查询到数据！");
            }
            Map pm = new HashMap<>();
            Class<? extends Plc> pClass = p.getClass();
            Field[] declaredFields = pClass.getDeclaredFields();
            for(Field f:declaredFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(p);
                if(value == null){
                    value = 0.00f;
                }
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
                bigMap.put(fname+""+i,v);
            }

//            Map m = new HashMap<>();
//            m.put("p_"+i, pm);
//            wswData.add(pm);
        }

        // 电表数据
        Db db_d = dbMapper.selectDbData(bid, "1");//低区电表
        if(db_d == null){
            log.info("泵站"+bid+"未查询到低区电表数据！");
//            throw new GlobalException("泵站"+bid+"未查询到数据！");
        }else{
            Class<? extends Db> db_dClass = db_d.getClass();
            Field[] db_dFields = db_dClass.getDeclaredFields();
            for(Field f:db_dFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(db_d);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-d",v);
                bigMap.put(fname+"d",v);
            }
        }



        Db db_z = dbMapper.selectDbData(bid, "2");//中区电表
        if(db_z == null){
            log.info("泵站"+bid+"未查询到中区电表数据！");
        }else{
            Class<? extends Db> db_zClass = db_z.getClass();
            Field[] db_zFields = db_zClass.getDeclaredFields();
            for(Field f:db_zFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(db_z);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-z",v);
                bigMap.put(fname+"z",v);
            }
        }



        Db db_g = dbMapper.selectDbData(bid, "3");//高区电表
        if(db_g == null){
            log.info("泵站"+bid+"未查询到中区电表数据！");
        }else{
            Class<? extends Db> db_gClass = db_g.getClass();
            Field[] db_gFields = db_gClass.getDeclaredFields();
            for(Field f:db_gFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(db_g);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-g",v);
                bigMap.put(fname+"g",v);
            }
        }

        // 机组数据、
        // 低区机组
        Jz jz_d = jzMapper.selectJzData(bid, "1");//低区机组
        if(jz_d == null){
            log.info("泵站"+bid+"未查询到低区机组数据！");
        }else{
            Class<? extends Jz> jz_dClass = jz_d.getClass();
            Field[] jz_dFields = jz_dClass.getDeclaredFields();
            for(Field f:jz_dFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(jz_d);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-d",v);
                bigMap.put(fname+"d",v);
            }

        }


        //中区机组
        Jz jz_z = jzMapper.selectJzData(bid, "2");//中区机组
        if(jz_z == null){
            log.info("泵站"+bid+"未查询到中区机组数据！");
        }else{
            Class<? extends Jz> jz_zClass = jz_z.getClass();
            Field[] jz_zFields = jz_zClass.getDeclaredFields();
            for(Field f:jz_zFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(jz_z);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-z",v);
                bigMap.put(fname+"z",v);
            }
        }


        //高区机组
        Jz jz_g = jzMapper.selectJzData(bid, "3");//高区机组
        if(jz_g == null){
            log.info("泵站"+bid+"未查询到高区机组数据！");
        }else{
            Class<? extends Jz> jz_gClass = jz_g.getClass();
            Field[] jz_gFields = jz_gClass.getDeclaredFields();
            for(Field f:jz_gFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(jz_g);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-g",v);
                bigMap.put(fname+"g",v);
            }

        }

        // 机组数据、
        // 中低区机组
        Jz jz_zd = jzMapper.selectJzData(bid, "4");//低区机组
        if(jz_zd == null){
            log.info("泵站"+bid+"未查询到中低区机组数据！");
        }else{
            Class<? extends Jz> jz_zdClass = jz_zd.getClass();
            Field[] jz_zdFields = jz_zdClass.getDeclaredFields();
            for(Field f:jz_zdFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(jz_zd);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
//                bigMap.put(fname+"-zd",v);
                bigMap.put(fname+"zd",v);
            }

        }

        //进口瞬时流量、进口累计流量
        Map map = jzMapper.selectJkssll(bid);
        Map sjll = new HashMap<>();
        sjll.put("value",map.get("sjll"));
        sjll.put("time",dateStr);
        bigMap.put("jkssll",sjll);
        Map ljll = new HashMap<>();
        ljll.put("value",map.get("ljll"));
        ljll.put("time",dateStr);
        bigMap.put("jkljll",ljll);

        // 水质仪表
        Sz sz = szMapper.selectSzData(bid);
        if(sz == null){
            log.info("泵站"+bid+"未查询到水质仪表数据！");
        }else{
            Class<? extends Sz> szClass = sz.getClass();
            Field[] szFields = szClass.getDeclaredFields();
            for(Field f:szFields){
                f.setAccessible(true);
                String fname = f.getName();
                Object value = f.get(sz);
                Map v = new HashMap<>();
                v.put("value",value);
                v.put("time",dateStr);
                bigMap.put(fname,v);
            }
        }


        wswData.add(bigMap);

        String endNum = "";
        if(bid < 10){
            endNum = "0" + bid;
        }else{
            endNum = bid + "";
        }
        String clientId = "KN202400012024" + endNum;
        MqttReq mqttReq = new MqttReq();
        mqttReq.setClientID(clientId);
        mqttReq.setPver("12");
        mqttReq.setType("dataUpload");
        mqttReq.setTime(dateStr);
        String msgId = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", new Date());
        mqttReq.setMsgId(msgId);

        Map data = new HashMap<>();
        data.put("wswData",wswData);
        mqttReq.setData(data);

        log.info("泵站"+endNum);

        return mqttReq;
    }


//    public MqttReq selectWswDataList0(Long bid) throws NoSuchFieldException, IllegalAccessException {
//
//        List wswData = new ArrayList();
//
//        // 数据时间
//        Map CommonData = commonDataMapper.selectHjAndMjData(bid);
//        Date timeBegin = (Date)CommonData.get("timeBegin");
//        System.out.println(timeBegin);
//        String dateStr = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", timeBegin);
//
//        // 环境监测
//        Map<Object, Object> hjData = new HashMap();
//        Object yg = CommonData.get("yg");
//        Map ygm = new HashMap<>();
//        ygm.put("time",dateStr);
//        ygm.put("value",yg);
//        Object sj = CommonData.get("sj");
//        Map sjm = new HashMap<>();
//        sjm.put("time",dateStr);
//        sjm.put("value",sj);
//        Object rq = CommonData.get("rq");
//        Map rqm = new HashMap<>();
//        rqm.put("time",dateStr);
//        rqm.put("value",rq);
//
//        hjData.put("yg",ygm);
//        hjData.put("sj",sjm);
//        hjData.put("rq",rqm);
//
//        Map hj = new HashMap<>();
//        hj.put("hj",hjData);
//
//        wswData.add(hj);
//
//        //门禁
//        Map<Object, Object> mjData = new HashMap();
//        Object zt = CommonData.get("zt");
//        Map ztm = new HashMap<>();
//        ztm.put("time",dateStr);
//        ztm.put("value",zt);
//        mjData.put("zt",ztm);
//
//        Map mj = new HashMap<>();
//        mj.put("mj",mjData);
//
//        wswData.add(mj);
//
//
//        Map tb = new HashMap<>();
//        tb.put("timeBegin",dateStr);
//        wswData.add(tb);
//
//        //plc总数
//        int plcCounts = 12;
//
//        for( int i = 1; i <= plcCounts; i++ ){
//            Plc p = plcMapper.selectPlcData(bid, i);
//            Map pm = new HashMap<>();
//            Class<? extends Plc> pClass = p.getClass();
//            Field[] declaredFields = pClass.getDeclaredFields();
//            for(Field f:declaredFields){
//                f.setAccessible(true);
//                String fname = f.getName();
//                Object value = f.get(p);
//                Map v = new HashMap<>();
//                v.put("value",value);
//                v.put("time",dateStr);
//                pm.put(fname,v);
//            }
//
//            Map m = new HashMap<>();
//            m.put("p_"+i, pm);
//            wswData.add(m);
//        }
//
//        // 电表数据
//        Db db_d = dbMapper.selectDbData(bid, "1");//低区电表
//        Map db_dm = new HashMap<>();
//        Class<? extends Db> db_dClass = db_d.getClass();
//        Field[] db_dFields = db_dClass.getDeclaredFields();
//        for(Field f:db_dFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(db_d);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            db_dm.put(fname,v);
//        }
//        Map dbd = new HashMap<>();
//        dbd.put("db_d",db_dm);
//        wswData.add(dbd);
//
//
//        Db db_z = dbMapper.selectDbData(bid, "2");//中区电表
//        Map db_zm = new HashMap<>();
//        Class<? extends Db> db_zClass = db_z.getClass();
//        Field[] db_zFields = db_zClass.getDeclaredFields();
//        for(Field f:db_zFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(db_z);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            db_zm.put(fname,v);
//        }
//        Map dbz = new HashMap<>();
//        dbz.put("db_z",db_zm);
//        wswData.add(dbz);
//
//        Db db_g = dbMapper.selectDbData(bid, "3");//高区电表
//        Map db_gm = new HashMap<>();
//        Class<? extends Db> db_gClass = db_g.getClass();
//        Field[] db_gFields = db_gClass.getDeclaredFields();
//        for(Field f:db_gFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(db_g);
//            System.out.println("字段"+fname+"：值为---"+value);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            db_gm.put(fname,v);
//        }
//
//        Map dbg = new HashMap<>();
//        dbg.put("db_g",db_gm);
//        wswData.add(dbg);
//
//
//        // 机组数据、
//        // 低区机组
//        Jz jz_d = jzMapper.selectJzData(bid, "1");//低区机组
//        Map jz_dm = new HashMap<>();
//        Class<? extends Jz> jz_dClass = jz_d.getClass();
//        Field[] jz_dFields = jz_dClass.getDeclaredFields();
//        for(Field f:jz_dFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(jz_d);
//            System.out.println("字段"+fname+"：值为---"+value);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            jz_dm.put(fname,v);
//        }
//
//        Map jzd = new HashMap<>();
//        jzd.put("jz_d",jz_dm);
//        wswData.add(jzd);
//
//        //中区机组
//        Jz jz_z = jzMapper.selectJzData(bid, "2");//中区机组
//        Map jz_zm = new HashMap<>();
//        Class<? extends Jz> jz_zClass = jz_z.getClass();
//        Field[] jz_zFields = jz_zClass.getDeclaredFields();
//        for(Field f:jz_zFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(jz_z);
//            System.out.println("字段"+fname+"：值为---"+value);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            jz_zm.put(fname,v);
//        }
//
//        Map jzz = new HashMap<>();
//        jzz.put("jz_z",jz_zm);
//        wswData.add(jzz);
//
//        //高区机组
//        Jz jz_g = jzMapper.selectJzData(bid, "3");//高区机组
//        Map jz_gm = new HashMap<>();
//        Class<? extends Jz> jz_gClass = jz_g.getClass();
//        Field[] jz_gFields = jz_gClass.getDeclaredFields();
//        for(Field f:jz_gFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(jz_g);
//            System.out.println("字段"+fname+"：值为---"+value);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            jz_gm.put(fname,v);
//        }
//
//        Map jzg = new HashMap<>();
//        jzg.put("jz_g",jz_gm);
//        wswData.add(jzg);
//
//
//        // 水质仪表
//        Sz sz = szMapper.selectSzData(bid);
//        Map szm = new HashMap<>();
//        Class<? extends Sz> szClass = sz.getClass();
//        Field[] szFields = szClass.getDeclaredFields();
//        for(Field f:szFields){
//            f.setAccessible(true);
//            String fname = f.getName();
//            Object value = f.get(sz);
//            System.out.println("字段"+fname+"：值为---"+value);
//            Map v = new HashMap<>();
//            v.put("value",value);
//            v.put("time",dateStr);
//            szm.put(fname,v);
//        }
//        Map sm = new HashMap<>();
//        sm.put("sz",szm);
//        wswData.add(sm);
//
//        //wswData.setDataNum();
//        String endNum = "";
//        if(bid < 10){
//            endNum = "0" + bid;
//        }else{
//            endNum = bid + "";
//        }
//        String clientId = "KN202400012024" + endNum;
//        MqttReq mqttReq = new MqttReq();
//        mqttReq.setClientID(clientId);
//        mqttReq.setPver("12");
//        mqttReq.setType("dataUpload");
//        mqttReq.setTime(dateStr);
//        String msgId = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", new Date());
//        mqttReq.setMsgId(msgId);
//
//        Map data = new HashMap<>();
//        Map dataUploadReq = new HashMap<>();
//        dataUploadReq.put("wswData",wswData);
//        data.put("dataUploadReq",dataUploadReq);
//        mqttReq.setData(data);
//
//
//        return mqttReq;
//    }
//
//
//
//    @Override
//    public MqttReq selectWswDataList1() throws NoSuchFieldException, IllegalAccessException {
//
//
//        Long bid = 1l;
//
//        List wswData = new ArrayList();
//
//
//        //plc总数
//        int plcCounts = 12;
//
//        for( int i = 1; i <= 12; i++ ){
//            Plc p = plcMapper.selectPlcData(bid, i);
//            Map m = new HashMap<>();
//            m.put("p_"+i, p);
//            wswData.add(m);
//        }
//
//        // 电表数据
//        Db db_d = dbMapper.selectDbData(bid, "1");//低区电表
//        Db db_z = dbMapper.selectDbData(bid, "2");//中区电表
//        Db db_g = dbMapper.selectDbData(bid, "3");//高区电表
//        Map dbd = new HashMap<>();
//        dbd.put("db_d",db_d);
//        Map dbz = new HashMap<>();
//        dbd.put("db_z",db_z);
//        Map dbg = new HashMap<>();
//        dbd.put("db_g",db_g);
//        wswData.add(dbd);
//        wswData.add(dbz);
//        wswData.add(dbg);
//
//
//        // 机组数据
//        Jz jz_d = jzMapper.selectJzData(bid, "1");//低区机组
//        Jz jz_z = jzMapper.selectJzData(bid, "2");//中区机组
//        Jz jz_g = jzMapper.selectJzData(bid, "3");//高区机组
//
//        Map jzd = new HashMap<>();
//        dbd.put("jz_d",jz_d);
//        Map jzz = new HashMap<>();
//        dbd.put("jz_z",jz_z);
//        Map jzg = new HashMap<>();
//        dbd.put("jz_g",jz_g);
//        wswData.add(jzd);
//        wswData.add(jzz);
//        wswData.add(jzg);
//
//
//        // 水质仪表
//        Sz sz = szMapper.selectSzData(bid);
//        Map szm = new HashMap<>();
//        dbd.put("sz",sz);
//        wswData.add(szm);
//
//        // 环境监测、门禁设备、数据时间
//        Map CommonData = commonDataMapper.selectHjAndMjData(bid);
//        Map<Object, Object> hjData = new HashMap();
//        Map<Object, Object> mjData = new HashMap();
//        hjData.put("yg",CommonData.get("yg"));
//        hjData.put("sj",CommonData.get("sj"));
//        hjData.put("rq",CommonData.get("rq"));
//        mjData.put("zt",CommonData.get("zt"));
//
//        Map mj = new HashMap<>();
//        mj.put("mj",mjData);
//        Map hj = new HashMap<>();
//        hj.put("hj",hjData);
//        wswData.add(mj);
//        wswData.add(hj);
//
//        Date timeBegin = (Date)CommonData.get("timeBegin");
//        System.out.println(timeBegin);
//        String dateStr = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", timeBegin);
//
//        Map tb = new HashMap<>();
//        tb.put("timeBegin",dateStr);
//        wswData.add(tb);
//
//        //wswData.setDataNum();
//
//        String clientId = "KN20240001202404";
//        MqttReq mqttReq = new MqttReq();
//        mqttReq.setClientID(clientId);
//        mqttReq.setPver("12");
//        mqttReq.setType("dataUpload");
//        mqttReq.setTime(dateStr);
//        String msgId = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", new Date());
//        mqttReq.setMsgId(msgId);
//
//        Map data = new HashMap<>();
//        Map dataUploadReq = new HashMap<>();
//        dataUploadReq.put("wswData",wswData);
//        data.put("dataUploadReq",dataUploadReq);
//        mqttReq.setData(data);
//
//
//        return mqttReq;
//    }
//
//    @Override
//    public MqttReq selectWswDataList2() throws NoSuchFieldException, IllegalAccessException {
//
//
//        Long bid = 1l;
//
//        WswData wswData = new WswData();
//
//
//        //plc总数
//        int plcCounts = 12;
//
//        for( int i = 1; i <= 12; i++ ){
//            Plc p = plcMapper.selectPlcData(bid, i);
//            // 获取字段的反射对象
//            Field field = wswData.getClass().getDeclaredField("p_"+i);
//            // 设置字段的访问权限，以便我们可以赋值
//            field.setAccessible(true);
//            // 为字段赋值
//            field.set(wswData, p);
//        }
//
//        // 电表数据
//        Db db_d = dbMapper.selectDbData(bid, "1");//低区电表
//        Db db_z = dbMapper.selectDbData(bid, "2");//中区电表
//        Db db_g = dbMapper.selectDbData(bid, "3");//高区电表
//        wswData.setDb_d(db_d);
//        wswData.setDb_z(db_z);
//        wswData.setDb_g(db_g);
//
//        // 机组数据
//        Jz jz_d = jzMapper.selectJzData(bid, "1");//低区机组
//        Jz jz_z = jzMapper.selectJzData(bid, "2");//中区机组
//        Jz jz_g = jzMapper.selectJzData(bid, "3");//高区机组
//        wswData.setJz_d(jz_d);
//        wswData.setJz_z(jz_z);
//        wswData.setJz_g(jz_g);
//
//        // 水质仪表
//        Sz sz = szMapper.selectSzData(bid);
//        wswData.setSz(sz);
//
//        // 环境监测、门禁设备、数据时间
//        Map CommonData = commonDataMapper.selectHjAndMjData(bid);
//        Map<Object, Object> hjData = new HashMap();
//        Map<Object, Object> mjData = new HashMap();
//        hjData.put("yg",CommonData.get("yg"));
//        hjData.put("sj",CommonData.get("sj"));
//        hjData.put("rq",CommonData.get("rq"));
//        mjData.put("zt",CommonData.get("zt"));
//        wswData.setMj(mjData);
//        wswData.setHj(hjData);
//
//        Date timeBegin = (Date)CommonData.get("timeBegin");
//        System.out.println(timeBegin);
//        String dateStr = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", timeBegin);
//        wswData.setTimeBegin(dateStr);
//
//        //wswData.setDataNum();
//
//        String clientId = "KN20240001202404";
//        MqttReq mqttReq = new MqttReq();
//        mqttReq.setClientID(clientId);
//        mqttReq.setPver("12");
//        mqttReq.setType("dataUpload");
//        mqttReq.setTime(dateStr);
//        String msgId = DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", new Date());
//        mqttReq.setMsgId(msgId);
//
//        Map data = new HashMap<>();
//        Map dataUploadReq = new HashMap<>();
//        dataUploadReq.put("wswData",wswData);
//        data.put("dataUploadReq",dataUploadReq);
//        mqttReq.setData(data);
//
//
//        return mqttReq;
//    }
}
